

package com.hazelcast.jet.pipeline;

/**
 * When passed to an IMap/ICache Event Journal source, specifies which
 * event to start from. You can start from the oldest event still in the
 * journal or skip all the history and receive only the events that
 * occur after connecting to the event journal.
 * <p>
 * See:
 * <ul>
 *     <li>{@link Sources#mapJournal}
 *     <li>{@link Sources#remoteMapJournal}
 *     <li>{@link Sources#cacheJournal}
 *     <li>{@link Sources#remoteCacheJournal}
 * </ul>
 *
 * @since Jet 3.0
 */
public enum JournalInitialPosition {

    /**
     * Start from the oldest event still available.
     */
    START_FROM_OLDEST,

    /**
     * Skip all the history and emit only the events that occur after
     * connecting to the journal.
     */
    START_FROM_CURRENT
}
